1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
<script>
import { DateTime } from 'luxon';
import { page } from '$app/state';
import MessageInput from '$lib/components/MessageInput.svelte';
import MessageRun from '$lib/components/MessageRun.svelte';
import Message from '$lib/components/Message.svelte';
import { runs } from '$lib/runs.js';
const { data } = $props();
const { session, outbox } = data;
let activeChannel;
const channelId = $derived(page.params.channel);
const channel = $derived(session.channels.find((channel) => channel.id === channelId));
const messages = $derived(session.messages.filter((message) => message.channel === channelId));
const unsent = $derived(outbox.messages.filter((message) => message.channel === channelId));
const deleted = $derived(outbox.deleted.map((message) => message.messageId));
const unsentSkeletons = $derived(
unsent.map((message) => message.toSkeleton($state.snapshot(session.currentUser))),
);
const messageRuns = $derived(runs(messages.concat(unsentSkeletons), session.currentUser));
function inView(parentElement, element) {
const parRect = parentElement.getBoundingClientRect();
const parentTop = parRect.top;
const parentBottom = parRect.bottom;
const elRect = element.getBoundingClientRect();
const elementTop = elRect.top;
const elementBottom = elRect.bottom;
return parentTop < elementTop && parentBottom > elementBottom;
}
function getLastVisibleMessage() {
if (activeChannel) {
const childElements = activeChannel.getElementsByClassName('message');
const lastInView = Array.from(childElements)
.reverse()
.find((el) => {
return inView(activeChannel, el);
});
return lastInView;
}
}
function setLastRead() {
const lastInView = getLastVisibleMessage();
const at = !!lastInView ? DateTime.fromISO(lastInView.dataset.at) : channel?.at;
if (!!at) {
session.local.updateLastReadAt(channelId, at);
}
}
$effect(() => {
const _ = session.messages;
setLastRead();
});
$effect(() => {
// This is just to force it to track messageRuns.
const _ = messageRuns;
document.querySelector('.message-run:last-child .message:last-child')?.scrollIntoView();
});
function handleKeydown(event) {
if (event.key === 'Escape') {
setLastRead(); // TODO: pass in "last message DT"?
}
}
let lastReadCallback = null;
function onscroll() {
clearTimeout(lastReadCallback); // Fine if lastReadCallback is null still.
lastReadCallback = setTimeout(setLastRead, 2 * 1000);
}
async function sendMessage(message) {
outbox.postToChannel(channelId, message);
}
async function deleteMessage(id) {
outbox.deleteMessage(id);
}
</script>
<svelte:window onkeydown={handleKeydown} />
<div class="active-channel" {onscroll} bind:this={activeChannel}>
{#each messageRuns as { sender, ownMessage, messages }}
<MessageRun
{sender}
class={{
['own-message']: ownMessage,
['other-message']: !ownMessage,
}}
>
{#each messages as message}
<Message
{...message}
editable={ownMessage}
{deleteMessage}
class={{
unsent: !message.id,
deleted: deleted.includes(message.id),
}}
/>
{/each}
</MessageRun>
{/each}
</div>
<div class="create-message">
<MessageInput {sendMessage} />
</div>
|
